package com.baizhi;

import org.apache.activemq.Message;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Service;

import javax.jms.JMSException;
import javax.jms.TextMessage;

/**
 * @author luxiaoyang
 * @create 2020-03-23-11:13
 */
@Service
public class MqBootListener {

    /**
     *  @JmsListener 可以把一个方法变为 Mq的监听器方法
     *  方法的形参必须为 Message
     *  该方法不需要手动调用 在项目启动之后 SpringBoot会自动进行调用
     */
    @JmsListener(destination = "mq-boot")
    public void bootListener(Message message){
        TextMessage textMessage = (TextMessage) message;

        try {
            System.out.println(textMessage.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}